import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.common.RemotingHelper;

public class Producer {
    public static void main(String[] args) throws Exception {
        //消费者组
        DefaultMQProducer producer = new DefaultMQProducer("mq-hello-producer-group");
        //2.设置NameServer地址
        producer.setNamesrvAddr("127.0.0.1:9876");
        // 启动Producer实例
        producer.start();
        //发送消息
        //要发送消息   先要有一条消息
        //应该有   一个对象   封装了消息


        //调用Message的构造方法
        //传三个参数


        //topic ( String )   tag ( String )
        //topic 和  tag  就是对消息做分类
        //topic是消息的一级分类   tag是二级分类
        //消费者  消费消息的时候   可以指定topic 和tag


        //第三个参数 就是需要发送的消息
        //是一个byte[]
        byte[] msgByteArray = "老铁".getBytes(RemotingHelper.DEFAULT_CHARSET);

        Message message = new Message("hello-topic", "hello-tag", msgByteArray);
        //发信息
        SendResult send = producer.send(message);
        System.out.println(send);
        // 如果不再发送消息，关闭Producer实例。
        producer.shutdown();

    }
}
